package com.my.test.thread.conditition.old;

public class Consumer extends Thread {

	@Override
	public void run() {
		MyQueue<String> myQueue = TestMyQueue.myQueue;
		while(true) {
			try {
				System.out.println("消费数据："+myQueue.remove());
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}

	}
}
